package io.confluent.kafka.consumer.controller;

import io.confluent.kafka.consumer.conf.PropertiesReader;
import io.confluent.kafka.consumer.core.ConsumerEvent;

/**
 * Created by taotao on 2017/12/18.
 */
public class EventAlarmControler {
    public static void main(String[] args) {
        String topics = PropertiesReader.KAFKA_CONSUMER_TOPICS_EVENT;
        ConsumerEvent consumerEventThread = new ConsumerEvent(topics);
        consumerEventThread.start();
    }
}
